
// 定义api请求域名
var baseUrl = ''
if (process.env.NODE_ENV === 'development') {
	console.log('开发环境');
	baseUrl = 'wss://localhost:54188/tkServer'//测试域名
} else {
	console.log('生产环境');
	baseUrl = 'wss://www.tkzsbserver.work:54188/tkServer';//正式域名
}

class socketIo{
	constructor(uid){
		this.uid = uid;
		this.socketTask = null;
		this.is_open_socket = false //避免重复连接
		this.url = baseUrl+'/websocket/'  //连接地址
		this.reconnectTimeOut = null //重连之后多久再次重连
	}
	
	connectSocketInit(){
		this.socketTask = uni.connectSocket({
			url: this.url+this.uid,
			success: () => {
				console.log("正准备建立websocket中...");
				// 返回实例
				return this.socketTask
			},
		});
		this.socketTask.onOpen((res) => {
			console.log("WebSocket连接正常！");
			// 关闭重连
			clearInterval(this.reconnectTimeOut)
			this.is_open_socket = true;
			// 注：只有连接正常打开中 ，才能正常收到消息
			this.socketTask.onMessage((e) => {
				// 字符串转json
				let res = JSON.parse(e.data);
				console.log("res---------->", res) // 这里 查看 推送过来的消息
				if (res.data) {
					uni.$emit('getWebSocketMessage', res); 
				}
			});
		})
		
		// 监听连接失败，这里代码我注释掉的原因是因为如果服务器关闭后，和下面的onclose方法一起发起重连操作，这样会导致重复连接
		uni.onSocketError((res) => {
			console.log('WebSocket连接打开失败');
			this.socketTask = null
			this.is_open_socket = false;
			this.reconnect();
		})
		
		// 这里仅是事件监听【如果socket关闭了会执行】
		this.socketTask.onClose(() => {
			console.log("WebSocket已经被关闭了")
			this.is_open_socket = false;
			this.socketTask = null
			this.reconnect();
		})
	}
	
	//重新连接
	reconnect() {
		if(this.reconnectTimeOut != null){
			return;
		}
		this.reconnectTimeOut = setInterval(() => {
			this.connectSocketInit();
		}, 10000)
	}
}

function getNewSocket(uid){
	return new socketIo(uid)
}

export {
	getNewSocket
} 
